package mq

import (
	"context"
	"paper-pro/app/chat/jobs/batchinsert/internal/config"
	"paper-pro/app/chat/jobs/batchinsert/internal/consumer"
	"paper-pro/app/chat/jobs/batchinsert/internal/svc"
	"paper-pro/pkg/kqutil"

	"github.com/zeromicro/go-zero/core/service"
)

func Consumers(c config.Config, ctx context.Context, svcContext *svc.ServiceContext) []service.Service {
	return []service.Service{
		kqutil.NewMultiWorkerConsumer(c.MwConsumerConf, ctx, consumer.NewBatchInsertConsumer(ctx, svcContext)),
	}
}
